//1.引入mysql 模块
const mysql = require("mysql");
//2.创建连接池对象
const pool = mysql.createPool({
    host: "127.0.0.1",
    user: "root",
    password: "root",
    database: "meituaninfo",
    port: 3306
})
//3. 封装一个exec函数 在函数内部返回一个promise对象
const exec = (sql, params) => {
    return new Promise(function (resolve, reject) {
        //conn  连接对象
        //4.在连接池里获取连接对象
        pool.getConnection((err,conn)=>{
            if(err){
                console.log("连接数据库失败");
                reject(err)
            }
            //5.通过连接对象,执行sql语句 获取结果
            conn.query(sql,params,(err,result)=>{
                    if(err){
                        console.log("执行数据库失败");
                        reject(err)
                    }
                    resolve(result);
                    //6.释放连接
                    conn.release()            
            })
        })
    })
}
//暴露
module.exports={
    exec
}